// package springtest.nettySocketio;
//
// import javax.websocket.Session;
//
// import org.springframework.boot.CommandLineRunner;
// import org.springframework.core.annotation.Order;
// import org.springframework.stereotype.Service;
//
// import com.corundumstudio.socketio.AckRequest;
// import com.corundumstudio.socketio.Configuration;
// import com.corundumstudio.socketio.SocketIOClient;
// import com.corundumstudio.socketio.SocketIOServer;
// import com.corundumstudio.socketio.listener.ConnectListener;
// import com.corundumstudio.socketio.listener.DataListener;
//
/// ***
// *
// * @author chenzhiqiang*@date 2018-07-03 09:45:16
// */
// @Service
// public class TestSocketIO implements CommandLineRunner {
// Session session;
//
// @Order(1)
// public void run(String... args) throws Exception {
// Configuration con = new Configuration();
// con.setHostname("localhost");
// con.setPort(8088);
// SocketIOServer server = new SocketIOServer(con);
// server.addConnectListener(new ConnectListener() {
//
// public void onConnect(SocketIOClient client) {
// System.out.println("客户端接入");
//
// client.sendEvent("hello", "hello");
//
// }
// });
// server.addEventListener("testSocket", User.class, new DataListener<User>() {
//
// @Override
// public void onData(SocketIOClient client, User data, AckRequest ackSender)
// throws Exception {
// client.sendEvent("hello", data);
// }
// });
// System.out.println("服务启动");
// server.start();
// }
//
// public static void main(String[] args) {
// Configuration con = new Configuration();
// con.setHostname("localhost");
// con.setPort(8088);
// SocketIOServer server = new SocketIOServer(con);
// server.addConnectListener(new ConnectListener() {
//
// public void onConnect(SocketIOClient client) {
// System.out.println("客户端接入");
// client.sendEvent("hello", "hello");
//
// }
// });
// server.addEventListener("testSocket", User.class, new DataListener<User>() {
//
// @Override
// public void onData(SocketIOClient client, User data, AckRequest ackSender)
// throws Exception {
// client.sendEvent("hello", data);
// }
// });
// System.out.println("服务启动");
// server.start();
// }
// }
